package com.ogawa.base.mqtt;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * mqtt收到消息
 */
public interface MqttReceiveListener {
    void onReceiveMqttMsg(String topic, MqttMessage message);
}
